package com.thinkingcoder.tcmq.client;

import com.thinkingcoder.tcmq.core.model.Message;

import lombok.AllArgsConstructor;

/**
 * message queue producer.
 */
@AllArgsConstructor
public class TcProducer {
    TcBroker broker;

    public boolean send(String topic, Message message) {
        return broker.send(topic, message);
    }
}
